package com.dtwave.lnstreaming.filter;

import com.alibaba.fastjson.JSONObject;
import com.dtwave.utils.JsonUtils;
import org.apache.flink.api.common.functions.RichFilterFunction;

import java.util.Objects;

public class XfaceFilterFunction extends RichFilterFunction<JSONObject> {

    @Override
    public boolean filter(JSONObject jsonObject) throws Exception {
        if (Objects.isNull(jsonObject)) {
            return false;
        } else {
            return true;
        }
    }
}
